﻿using System.Threading.Tasks;
using Cngot.Extensions.EventBus.Kafka.Integration;

namespace Cngot.Extensions.EventBus.Kafka
{
    public interface IKafkaConsumerListener
    {
        Task ConsumeAsync(RecieveResult recieveResult);
    }
}
